348456f6c59cd75a17f789ef58a7d82b56763fcf,src/test/java/io/github/robwin/cache/CacheTest.java,CacheTest,shouldInvokeDecoratedCallable,#,67

Before Change


        given(cache.get("testKey")).willReturn(null);

        Cache<String, String> cacheContext = Cache.of(cache);
        CircularEventConsumer<CacheEvent> cacheEventConsumer = new CircularEventConsumer<>(10);
        cacheContext.getEventStream()
                .subscribe(cacheEventConsumer);

        Try.CheckedFunction<String, String> cachedFunction = Cache.decorateCallable(cacheContext, () -> "Hello world");
        String value = cachedFunction.apply("testKey");

After Change



        Cache<String, String> cacheContext = Cache.of(cache);
        TestSubscriber<CacheEvent.Type> testSubscriber = cacheContext.getEventStream()
                .map(CacheEvent::getEventType)
                .test();

        Try.CheckedFunction<String, String> cachedFunction = Cache.decorateCallable(cacheContext, () -> "Hello world");
        String value = cachedFunction.apply("testKey");